﻿#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <dirent.h> //目录名获取配合DIR
#include <assert.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <unistd.h>
#include <fcntl.h> //文件控制操作
#include <sys/types.h> //获取pid等
#include <sys/wait.h> //等待子进程结束
#include <time.h> //时间获取
#include <sys/ipc.h> //进程通信
#include <sys/msg.h> //消息队列
#include <sys/shm.h> //共享内存
#include <signal.h> //信号处理
#include <pthread.h> //线程
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <semaphore.h>

struct threadpool
{
	sem_t semw;
	sem_t semr;
	pthread_mutex_t mutex;

	struct queue* que;
	pthread_t* tids;
	int queue_length_max;
	int sock;
};//线程池结构体
struct threadpool* create_threadpool(int threads, int queue_length, void* (*consumer)(void*), int sockres);
void destroy_threadpool(struct threadpool* p, int threads);